package com.angel.bo.common.handler.stomp;

/**
 * 消息接收方接收到消息时的处理动作
 */
public interface StompReceiveHandler {



    /**
     * 这个是异步执行的，并且支持多线程
     * @throws Exception
     */
    Object apply(Object payload);


}
